package com.lmy.rabbitmq.all;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * 使用Rabbitmq的java原生API，完成direct模式的生产者完整代码(包含交换机声明、队列声明、交换机与队列绑定)
 */
public class Producer {

    public static void main(String[] args) {

        //所有的中间件技术都是基于tcp/ip协议基础之上构建新型的协议规范，只不过rabbitmq遵循的是amqp
        //ip port
        //1.创建连接工厂
        ConnectionFactory connectionFactory = new ConnectionFactory();
        connectionFactory.setHost("169.254.27.100");
        connectionFactory.setPort(5672);
        connectionFactory.setUsername("admin");
        connectionFactory.setPassword("admin");
        //可以设置虚拟节点，起到隔离和区分的作用
        //类似于mysql中库的概念，可以为不同的业务设置不同的VirtualHost
        // /表示根节点
        connectionFactory.setVirtualHost("/");
        Connection connection = null;
        Channel channel = null;
        try {
            //2.创建连接Connection
            connection = connectionFactory.newConnection("生产者");
            //3.通过连接获取通道Channel
            channel = connection.createChannel();
            //4.通过通道创建交换机、队列、绑定关系、路由key、发送消息、接收消息
            String exchangeName = "direct_message_exchange";
            String type = "direct";
            String queueName1 = "queue100";
            String queueName2 = "queue200";
            String queueName3 = "queue300";
            String routingKey1 = "order";
            String routingKey2 = "store";
            //声明交换机，可以指定是否持久化，即是否随着服务器重启造成交换机丢失
            channel.exchangeDeclare(exchangeName, type, true);
            //声明队列，可以指定是否持久化，即是否随着服务器重启造成队列丢失
            channel.queueDeclare(queueName1, true, false, false, null);
            channel.queueDeclare(queueName2, true, false, false, null);
            channel.queueDeclare(queueName3, true, false, false, null);
            //将队列与交换机进行绑定，可以对每个绑定关系指定routingKey
            channel.queueBind(queueName1, exchangeName, routingKey1);
            channel.queueBind(queueName2, exchangeName, routingKey2);
            channel.queueBind(queueName3, exchangeName, routingKey2);
            //5.准备消息内容
            String message = "This is a direct message using java!";
            //6.发送消息给队列Queue
            /*
                发送消息有四个参数，分别为
                1.交换机名称
                2.队列、路由key
                3.消息的状态控制
                4.消息主体
                面试题：可以存在没有交换机的队列吗？ 不可能，虽然没有指定交换机，但是存在默认交换机
             */
            //这里向direct_exchange交换机发送消息，指定routingKey为store。根据上边的绑定关系，最终 queue200 和 queue300会接收到消息
            channel.basicPublish(exchangeName, routingKey2, null, message.getBytes());
        }  catch (Exception e) {
            e.printStackTrace();
        } finally {
            //7.关闭通道
            if (channel != null && channel.isOpen()) {
                try{
                    channel.close();
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
            //8.关闭连接
            if (connection != null && connection.isOpen()) {
                try{
                    connection.close();
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }

    }
}
